640760a2097a28fdcf8d7c3199ac114dfe2e68c8,src/main/java/ru/yandex/clickhouse/ClickHouseStatementImpl.java,ClickHouseStatementImpl,sendStream,#HttpEntity#String#,504
Before Change
URI uri = new URI("http", null, properties.getHost(), properties.getPort(), "/", query, null);
HttpPost httpPost = new HttpPost(uri);
httpPost.setEntity(content);
HttpResponse response = client.execute(httpPost);
entity = response.getEntity();
if (response.getStatusLine().getStatusCode() != HttpURLConnection.HTTP_OK) {
After Change
URI uri = new URI("http", null, properties.getHost(), properties.getPort(), "/", query, null);
HttpPost httpPost = new HttpPost(uri);
if (properties.isDecompress()){
httpPost.setEntity(new LZ4EntityWrapper(content, properties.getMaxCompressBufferSize()));
} else {
httpPost.setEntity(content);
}
HttpResponse response = client.execute(httpPost);
entity = response.getEntity();